package com.huc.rabbit.mq.config;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ChannelProxy;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitP2PConfig {

    public static final String QUEUE_NAME = "p2p.all";
    public static final String QUEUE_NAME_2 = "p2p.all.2";
    public static final String QUEUE_NAME_3 = "p2p.all.3";
    public static final String QUEUE_NAME_4 = "p2p.all.4";


    @Bean
    public Queue queueP2p(){
        return new Queue(QUEUE_NAME);
    }

    @Bean
    public Queue queueP2p2(){
        return new Queue(QUEUE_NAME_2);
    }

    @Bean
    public Queue queueP2p3(){
        return new Queue(QUEUE_NAME_3);
    }

    @Bean
    public Queue queueP2p4(){
        return new Queue(QUEUE_NAME_4);
    }

    @Bean
    public Queue test1(){
        return new Queue("test1");
    }

    @Bean
    public Queue test2(){
        return new Queue("test2");
    }

}
